package cn.doitedu.analy.groupon;

import org.apache.flink.api.common.functions.ReduceFunction;
import utils.HbaseUtil;

public class GrouponReducer implements ReduceFunction<GrouponEntity> {
    @Override
    public GrouponEntity reduce(GrouponEntity grouponEntity, GrouponEntity t1) throws Exception {

        GrouponEntity ent = new GrouponEntity();
        ent.setUserId(t1.getUserId());
        ent.setTimes(grouponEntity.getTimes()+t1.getTimes());

        return ent;
    }
}
